<?php
require_once("./banco/BancoMysql.php");
require "./base/Equipe.php";

class RepositorioEquipe {

	private $equipe;
	private $db;

	public function __construct($db = "MySQL") {
		$this->setDb($db);
	}

	public function setDb($valor) {
		$banco = "Banco" . $valor;
		$this->db = new $banco ();

		$this->db->setDb('weegodb');
	}

			
	public function selecionarEquipe($equipe=null, $idempresa) {
		$this->db->abrirConexao();
		$sql = "SELECT * FROM equipe WHERE empresa_id = ".$idempresa;
		if (!empty($equipe)) {
			$sql .= " AND nome = '". $equipe->getNome()."'" ;
		}

		if ( $this->db->executaConsulta($sql) ) {
			$matrizResult = $this->db->getResultSet();				
			return $matrizResult;
		} else {
			return null;
		}
		
		$this->db->fecharConexao();
	}		
	
	public function inserirEquipe($equipe, $idempresa) {
		$this->db->abrirConexao();
		$sql = "INSERT INTO equipe (nome, datacriacao, empresa_id) VALUES('?','?',?)";
		$sqlPartes = explode('?', $sql);
		
				
		$sql = 	$sqlPartes[0] . 
				$equipe->getNome() . $sqlPartes[1] . 				
				date('Y-m-d H:i:s') . $sqlPartes[2] . 
				$idempresa . $sqlPartes[3];
		
		if ( $this->db->executaComando($sql) ) {				
			$sql = "SELECT MAX(id) FROM equipe WHERE empresa_id = ".$idempresa;	
			if ( $this->db->executaConsulta($sql) ) {
				$matrizResult = $this->db->getResultSet();				
				return $matrizResult;			
			} else {
				return null;			
			}
		} else {
			return null;
		}
		$this->db->fecharConexao();
	}
	
	public function inserirMembroEquipe($idequipe, $usuarios) {
		$this->db->abrirConexao();
		
		$sql = "DELETE FROM equipe WHERE id = ".$idequipe;	
		if ( $this->db->executaConsulta($sql) ) {
			for($i=0; $i < count($tel); $i++){
				$sql = "INSERT INTO membro_equipe (equipe_id, usuario_id) VALUES (".$idequipe.",".$usuarios[$i].")";				
				$this->db->executaComando($sql);					
			}
			return true;			
		} else {
			return false;			
		}
		$this->db->fecharConexao();
	}
	
}
?>
